package com.jxb.ractBase;

import reactor.core.publisher.Flux;

/**
 * 类注释
 *
 * @author jiaobo
 * @date Created in 2024/10/23 21:31
 **/
public class OperationsTest {

    public static void main(String[] args) {
        Flux<String> just = Flux.just("a", "b", "c", "d", "e", "f");
        just
                // .take(5)
                // .takeLast(3)
                // .takeUntil(item -> item.equalsIgnoreCase("d"))
                .elementAt(1)
                .subscribe(System.out::println);
    }

}
